package org.chat.hhdchat.repository;

import org.chat.hhdchat.entity.ChatMessage;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.data.mongodb.repository.Query;

import java.util.List;

//属于数据访问层, MongoDB数据访问

public interface ChatMessageRepository extends MongoRepository<ChatMessage, String> {
    // 查询某个用户的未读消息（MongoDB方法名自动解析）
    List<ChatMessage> findByToUserIdAndIsReadFalse(String toUserId);

    //双向查询
    @Query("{ '$or': [ { 'toUserId': ?0, 'fromUserId': ?1 }, { 'toUserId': ?1, 'fromUserId': ?0 } ] }")
    List<ChatMessage> findByToUserIdAndFromUserId(String toUserId,String fromUserId);
}